
package com.gitee.flow.client;

import com.gitee.jmash.common.grpc.client.GrpcChannel;
import jakarta.enterprise.inject.spi.CDI;
import jmash.flow.FlowGrpc;

/** Flow Client . */
public class FlowClient {

  /** FlowBlockingStub. */
  public static FlowGrpc.FlowBlockingStub getFlowBlockingStub() {
    return CDI.current().select(FlowGrpc.FlowBlockingStub.class).get().withCallCredentials(GrpcChannel.getCallCredentials());
  }

  /** FlowFutureStub. */
  public static FlowGrpc.FlowFutureStub getFlowFutureStub() {
    return CDI.current().select(FlowGrpc.FlowFutureStub.class).get().withCallCredentials(GrpcChannel.getCallCredentials());
  }

  /** FlowStub. */
  public static FlowGrpc.FlowStub getFlowStub() {
    return CDI.current().select(FlowGrpc.FlowStub.class).get().withCallCredentials(GrpcChannel.getCallCredentials());
  }

}
